package github.sf.fw.tools.db.connector;


import github.sf.fw.tools.db.DSConnector;
import github.sf.fw.tools.db.DSProperty;

import java.io.IOException;

public class Neo4jConnector implements DSConnector {
//    private Session session;
    private DSProperty dsProperty;

    /**
     * 初始化neo4j连接
     *
     * @param dsProperty
     */
    public Neo4jConnector(DSProperty dsProperty) {
        this.dsProperty = dsProperty;
//        session = initNeo4JSession(dsProperty);
    }

//    /**
//     * 初始化neo4jsession方法
//     * @param dsProperty
//     * @return
//     */
//    private Session initNeo4JSession(DSProperty dsProperty) {
//        Driver driver = GraphDatabase.driver(dsProperty.getUrl(), AuthTokens.basic(dsProperty.getUsername(), dsProperty.getPassword()));
//        return driver.session();
//    }


    @Override
    public Object getConn() throws Exception {
        return null;
    }

    @Override
    public void close() throws IOException {

    }

    /**
     * 执行插入数据方法
     * @param sql
     */
    public void dowrite(String sql) {
//        if (session==null){
//            throw new RuntimeException("执行的seeion为空");
//        }
//        session.run(sql);
    }
}
